package com.ocom.mqsimple.business.ssgl.impl;

import com.ocom.mqsimple.business.person.impl.ImportPerSonProductServiceImpl;
import com.ocom.mqsimple.business.ssgl.SSGLProductService;
import com.ocom.mqsimple.utils.SSGLProductUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class SSGLProductServiceImpl implements SSGLProductService {
    private final Logger log = LoggerFactory.getLogger(ImportPerSonProductServiceImpl.class);

    @Autowired
    private SSGLProductUtil ssglProductUtil;

    @Override
    public void handle(String msg) {
        log.info(" SSGL-mq-开始【{}】", msg);
        //优先级越高越先执行完
        ssglProductUtil.send(msg, 10);

        log.info(" SSGL-mq-完成【{}】", msg);
    }
}
